15e3d31a4e6a86f20fa3ff211fc1eadcbecec17e,src/test/java/com/lambdaworks/redis/pubsub/PubSubRxTest.java,PubSubRxTest,pubsubChannels,#,197

Before Change



    @Test
    public void pubsubChannels() throws Exception {
        pubsub.subscribe(channel).toBlocking().singleOrDefault(null);
        List<String> result = pubsub2.pubsubChannels().toList().toBlocking().first();
        assertThat(result).contains(channel);
    }

After Change


    @Test
    public void pubsubChannels() throws Exception {

        block(pubsub.subscribe(channel));
        List<String> result = first(pubsub2.pubsubChannels().toList());
        assertThat(result).contains(channel);
    }